package com.evil.common.rocketmq.util;

import com.evil.common.redis.util.RedisKeyUtil;
import com.evil.common.rocketmq.constant.MSGRedisConstant;

/**
 * @author liyang
 * @date 2025-03-10 16:03
 */
public class MqRedisKeyUtil extends RedisKeyUtil {

    /**
     * 会话资源-MQ消息层级
     *
     * @return String
     */
    public static String requestUuidMqMsgLevelKey() {
        String requestUuid = RedisKeyUtil.requestUuid();
        return RedisKeyUtil.requestUuidKey(requestUuid) + ":" + MSGRedisConstant.MQ_MSG_LEVEL_KEY_PREFIX;
    }

    /**
     * 会话资源-MQ消息缓存
     *
     * @return String
     */
    public static String requestUuidMqMsgCacheKey() {
        String requestUuid = RedisKeyUtil.requestUuid();
        return RedisKeyUtil.requestUuidKey(requestUuid) + ":" + MSGRedisConstant.MQ_MSG_CACHE_KEY_PREFIX;
    }
}
